const fs = require('fs');
const path = require('path');
const UserModel = require("../../models/UserModel")

const directory = 'public/uploads/picture'; // 图片存储目录

// 检测是否使用
async function isFileInUse(filePath) {
  try {
    await UserModel.find({
        avatar: "",
    })
    return false;
  } catch (err) {
    return true;
  }
}

// 定期删除过期文件
setInterval(() => {
  fs.readdir(directory, (err, files) => {
    if (err) {
      console.error('读取目录失败:', err);
      return;
    }

    files.forEach(file => {
      const filePath = path.join(directory, file);
      if (isFileInUse(filePath)) {
        console.log(`文件正在使用中: ${filePath}`);
      } else {
        fs.unlink(filePath, err => {
          if (err) {
            console.error(`删除文件失败: ${filePath}`, err);
          } else {
            console.log(`已删除文件: ${filePath}`);
          }
        });
      }
    });
  });
},10000);